package com.larry.flume.sink;

import org.apache.flume.Context;
import org.apache.flume.EventDeliveryException;
import org.apache.flume.conf.Configurable;
import org.apache.flume.sink.AbstractSink;

/**
 * @ProjectName hadoop
 * @Author larry
 * @Date 21:02 2021/11/30
 * @Description 自定义sink
 **/
public class MySink extends AbstractSink implements Configurable {

    @Override
    public Status process() throws EventDeliveryException {
        return null;
    }

    @Override
    public void configure(Context context) {

    }
}
